Skip to content

BaseReplayLatestSubjectAsync class

Defined in

Namespace: ReactiveUI.Extensions.Async.Subjects Assembly: ReactiveUI.Extensions.dll Full name: ReactiveUI.Extensions.Async.Subjects.BaseReplayLatestSubjectAsync<T> Modifiers: public abstract

Summary

View source

        Provides a base implementation for an asynchronous subject that replays the latest value to new subscribers and
        supports asynchronous notification of observers.
        

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481

Class hierarchy
classDiagram
class BaseReplayLatestSubjectAsync~T~
class ObservableAsync~T~
ObservableAsync~T~ <|-- BaseReplayLatestSubjectAsync~T~
class ISubjectAsync~T~ {
    <>
}
ISubjectAsync~T~ <|.. BaseReplayLatestSubjectAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. BaseReplayLatestSubjectAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. BaseReplayLatestSubjectAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. BaseReplayLatestSubjectAsync~T~

Inherits from: ObservableAsync

Implements: ISubjectAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks

This abstract class is intended to be inherited by types that implement custom replay and notification logic for asynchronous observers. When a new observer subscribes, it immediately receives the latest value if one is available. The subject supports asynchronous notification of values, errors, and completion, and ensures thread-safe access for concurrent operations.

Constructors

NameSummary
.ctorProvides a base implementation for an asynchronous subject that replays the latest value to new subscribers and supports asynchronous notification of observers.

Methods

NameSummary
OnNextAsyncAsynchronously notifies all subscribed observers with the specified value.
OnErrorResumeAsyncNotifies all observers of an error and resumes asynchronous processing as appropriate.
OnCompletedAsyncNotifies all registered observers that the asynchronous operation has completed and provides the final result.
DisposeAsyncAsynchronously releases the unmanaged resources used by the object.
OnNextAsyncCoreAsynchronously notifies the specified observers with the provided value.
OnErrorResumeAsyncCoreHandles error recovery for the specified observers by resuming asynchronous processing after an error occurs.
OnCompletedAsyncCoreInvoked to asynchronously notify all observers of the completion event with the specified result.
SubscribeAsyncCoreSubscribes the specified asynchronous observer to receive notifications from the observable sequence.
Inherited members